#ifndef VIDEOANALYSISSYSTEM_VAS_ROCKETMQ_H
#define VIDEOANALYSISSYSTEM_VAS_ROCKETMQ_H

#include <string>

namespace vas {

    const char ROCKETMQ_PRODUCER_GROUP[] = "VAS";
    const char ROCKETMQ_TOPIC[] = "ChannelResult";
    extern std::string ROCKET_MQ_HOST;

    void RocketMQInit(const std::string &hosts);

    void RocketMQSend( const std::string &msg_str, const std::string &topic = ROCKETMQ_TOPIC);

    void RocketMQStop();
}

#endif //VIDEOANALYSISSYSTEM_VAS_ROCKETMQ_H
